@rm-openai i’ve resolved the merge conflict in tool_context.py. The branch is now up to date and ready for your feedback.

looking forward to this new feature

  if stream_inner_events:
      from .stream_events import RunItemStreamEvent
  
      sub_run = Runner.run_streamed(
          self,
          input=input,
          context=context.context,
      )
  
      parent_queue = getattr(context, "_event_queue", None)

When I test on my project, in the above codes in agent.py, the parent_queue will be None and the sub_run event will not be streaming, I manually init it as:

  parent_queue = asyncio.Queue()
  context._event_queue = parent_queue

It is right?

hey @yxh-y the queue is only attached when the outer‑most run itself is started in streaming mode. In other words, Runner.run_streamed(…) sets ctx._event_queue = streamed_result._event_queue before control reaches any nested agents or tools.

If you invoke the outer agent with the non‑streaming Runner.run(…), no queue is created, so parent_queue will be None inside Agent.as_tool(…, stream_inner_events=True).

So, rather than injecting your own asyncio.Queue(), call your top‑level agent like this:

run = Runner.run_streamed(root_agent, input=user_input, context=ctx)
async for ev in run.stream_events():
...

this ensures that ctx._event_queue is populated. Inner agents/tool calls that you wrapped with
child_agent.as_tool(stream_inner_events=True) can forward theirtool_called / tool_output events to the same queue, so they show up in the outer run.stream_events() stream.

tl;dr, if you start the outer run with run_streamed, the queue is set up automatically (no manual queue needed), and you’ll see the child events immediately.